//package com.allwees.data.dataport.module.product.mq.consume;
//
//import com.allwees.bs.core.model.product.entity.ProductModel;
//import com.allwees.data.dataport.module.product.doc.ProductSpu;
//import com.allwees.data.dataport.module.product.repository.es.ProductIndexEsRepository;
//import lombok.extern.slf4j.Slf4j;
////import org.springframework.amqp.rabbit.annotation.RabbitHandler;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.context.annotation.Lazy;
//import org.springframework.stereotype.Component;
//
///**
// * 更新索引Listener：product_spu（单个更新）
// *
// * @author yangylsky
// * @since 2019-11-19
// *
// */
//@Slf4j
//@Lazy(false)
//@Component
////@RabbitListener(queues = "q.Product.UpdateIndex")
//public class UpdateProductIndexListener {
//	@Autowired
//	private ProductIndexEsRepository productIndexEsRepository;
//
////	@RabbitHandler
//	public void processMessage(ProductModel product) {
//		log.info("receive message:{uuid: {}}", product.getUuid());
//		productIndexEsRepository.save(ProductSpu.fromProductModel(product));
//	}
//}
